package org.apache.flink.runtime.resourceconsumer.factories;

import javax.annotation.Nonnull;

import org.apache.flink.api.common.ConsumerID;
import org.apache.flink.runtime.metrics.groups.ConsumerManagerConsumerMetricGroup;

/** Factory interface for {@link ConsumerManagerConsumerMetricGroupFactory}. */
public interface ConsumerManagerConsumerMetricGroupFactory {

	ConsumerManagerConsumerMetricGroup create(@Nonnull ConsumerID resourceId, String consumerName);
	
}
